package cn.edu.zafu.bigdata.bd121.timer;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.nio.charset.StandardCharsets;

/**
 * 基于 UDP 的时钟同步程序
 * 要求：
 * 实现一个 UDP 服务端和客户端，客户端请求当前时间，服务端返回服务器的时间。
 * 能够将同学电脑作为服务端，并获取其时间。
 * <p>
 * 此为服务端
 * </p>
 *
 * @author 202211090121
 */
public class TimerServer {

    /**
     * 服务器端口
     */
    private static final int PORT = 1221;

    public static void main(String[] args) {
        try (DatagramSocket ds = new DatagramSocket(PORT)) {
            System.out.println("服务器启动，监听端口: " + PORT);
            while (true) {
                byte[] buffer = new byte[1024];
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                ds.receive(packet);
                String message = new String(packet.getData(), packet.getOffset(), packet.getLength(), StandardCharsets.UTF_8);
                System.out.println("接收到消息: " + message);
                if ("time".equals(message)) {
                    String currentTime = System.currentTimeMillis() + "";
                    byte[] data = currentTime.getBytes(StandardCharsets.UTF_8);
                    packet.setData(data);
                    ds.send(packet);
                }
            }
        } catch (Exception e) {
            System.err.println("错误: " + e.getMessage());
        }
    }
}
